package com.aabte.springcloudlearn.springcloudstream.mypipe;

import org.springframework.cloud.stream.annotation.Input;
import org.springframework.cloud.stream.annotation.Output;
import org.springframework.messaging.MessageChannel;
import org.springframework.messaging.SubscribableChannel;

/**
 * @author Daniel
 */
public interface MyPipe {

    String INPUT = "my-pipe-input";

    @Input(MyPipe.INPUT)
    SubscribableChannel input();

    String OUTPUT = "my-pipe-output";

    @Output(MyPipe.OUTPUT)
    MessageChannel output();

}
